package com.jake.rabbit.config;

import com.jake.common.constant.SizeConstants;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.time.LocalDateTime;
import java.util.Queue;
import java.util.concurrent.ArrayBlockingQueue;

@Configuration
public class ConcurrentConfig {
    
    @Bean
    public Queue<LocalDateTime> rabbitConcurrentQueue() {
        return new ArrayBlockingQueue<>(SizeConstants.RABBIT_THRESHOLD_SIZE);
    }
    
}
